home *** CD-ROM | disk | FTP | other *** search
/ Linux Cubed Series 3: Developer Tools / Linux Cubed Series 3 - Developer Tools.iso / devel / db / esm-3.1 / esm-3 / usr / local / sm / src / serverlib / util / utilFuncs.c < prev   
Encoding:
C/C++ Source or Header  |  1996-05-05  |  4.6 KB  |  219 lines
  1. /*
  2.  *   $RCSfile: utilFuncs.c,v $  
  3.  *   $Revision: 1.1.1.1 $  
  4.  *   $Date: 1996/05/04 21:56:03 $      
  5.  */ 
  6. /**********************************************************************
  7. * EXODUS Database Toolkit Software
  8. * Copyright (c) 1991 Computer Sciences Department, University of
  9. *                    Wisconsin -- Madison
  10. * All Rights Reserved.
  11. *
  12. * Permission to use, copy, modify and distribute this software and its
  13. * documentation is hereby granted, provided that both the copyright
  14. * notice and this permission notice appear in all copies of the
  15. * software, derivative works or modified versions, and any portions
  16. * thereof, and that both notices appear in supporting documentation.
  17. *
  18. * THE COMPUTER SCIENCES DEPARTMENT OF THE UNIVERSITY OF WISCONSIN --
  19. * MADISON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS" CONDITION.  
  20. * THE DEPARTMENT DISCLAIMS ANY LIABILITY OF ANY KIND FOR ANY DAMAGES
  21. * WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
  22. *
  23. * The EXODUS Project Group requests users of this software to return 
  24. * any improvements or extensions that they make to:
  25. *
  26. *   EXODUS Project Group 
  27. *     c/o David J. DeWitt and Michael J. Carey
  28. *   Computer Sciences Department
  29. *   University of Wisconsin -- Madison
  30. *   Madison, WI 53706
  31. *
  32. *     or exodus@cs.wisc.edu
  33. *
  34. * In addition, the EXODUS Project Group requests that users grant the 
  35. * Computer Sciences Department rights to redistribute these changes.
  36. **********************************************************************/
  37.  
  38. #include "ess.h"
  39. #include "checking.h"
  40. #include "sysdefs.h"
  41. #include "trace.h"
  42. #include "error.h"
  43. #include "io.h"
  44. #include "list.h"
  45. #include "tid.h"
  46. #include "lock.h"
  47. #include "object.h"
  48. #include "msgdefs.h"
  49. #include "thread.h"
  50. #include "semaphore.h"
  51. #include "link.h"
  52. #include "lsn.h"
  53. #include "latch.h"
  54. #include "bf.h"
  55. #include "volume.h"
  56. #include "pool.h"
  57. #include "server_util_funcs.h"
  58. #include "thread_globals.h"
  59. #include "disk_globals.h"
  60. #include "io_globals.h"
  61. #include "queue_consist.h"
  62. #include "disk_funcs.h"
  63. #include "io_extfuncs.h"
  64.  
  65. #ifdef DEBUG
  66. void
  67. checkMalloc()
  68. {
  69. #ifdef JUNK
  70.     static BOOL first = TRUE;
  71.     static char *prev = NULL;
  72.     char *current;
  73.     current = (char *)sbrk(0);
  74.     if(current != prev) {
  75.         if(!first) {
  76.             TRPRINT(TR_SHM, TR_LEVEL_1, ("Gained %d bytes!", current-prev));
  77.         }
  78.     }
  79.     prev = current;
  80.     first = FALSE;
  81. #endif JUNK
  82. }
  83. #endif DEBUG
  84.  
  85. /* 
  86.  * MonDump(BOOL, volRec)
  87.  * the 1st argument tells whether or not to dump the server process.
  88.  * the 2nd argument has 3 possible semantics:
  89.  *       if null
  90.  *            if environment variable PROFDIR is set, do all disk processes
  91.  *            else don't bother with disk processes
  92.  *       else points to volume to kick 
  93.  */
  94. #ifdef PROFIL
  95. BEGIN_EXTERNC
  96.     extern void  monitor(int);
  97.     extern void  moncontrol(int);
  98. END_EXTERNC
  99.  
  100. static BOOL
  101. ifOpenDoDump(
  102.     VOLREC         *volRec,
  103.     DISKMSG        *diskmessage,
  104.     int            *errloc
  105. ) 
  106. {
  107.     int error = 0;
  108.  
  109.     SM_ASSERT(LEVEL_1, (volRec->volflags & VOL_OPEN) );
  110.  
  111.     if(volRec->diskrwPid) {
  112.         if(callDisk(volRec, diskmessage)) 
  113.             error = Active->errno;
  114.     }
  115.     if(error)
  116.         *errloc = error;
  117.     return FALSE;
  118. }
  119. #endif PROFIL
  120.  
  121.  int
  122. MonDump (
  123.     BOOL            unused1,
  124.     VOLREC            *unused2
  125. )
  126. {
  127. #ifdef PROFIL
  128.     DISKMSG            *diskmessage;
  129.     int error;
  130.  
  131.     /* All this is under control of -DPROFIL so that
  132.      * one can make a version of the server that
  133.      * doesn't require the -p option (to get monstartup, etc
  134.      * linked in).
  135.      * The idea is that you compile with -p -DPROFIL or with
  136.      * neither.  
  137.      */
  138.  
  139.  
  140.     if(unused1) {
  141.         /* 
  142.          * cease monitoring for the moment, and write the
  143.          * mon.out file 
  144.          */
  145.         monitor(0); 
  146.         /* 
  147.          * resume, using the original buffer
  148.          */
  149.         moncontrol(1); 
  150.     }
  151.  
  152.     /* 
  153.      * Now tell diskrw(s) to do the same...
  154.      */
  155.     SM_ASSERT(LEVEL_1, Active!=NULL);
  156.     diskmessage = Active->diskMessage;
  157.     diskmessage->header.type = DUMP_MON;
  158.  
  159.     if(unused2) {
  160.         ifOpenDoDump(unused2, diskmessage, &error);
  161.     } else if(HasProfDir) {
  162.         ForEachVolume(2, ifOpenDoDump, diskmessage, &error, 0);
  163.     }
  164.     return error;
  165. #else PROFIL
  166.     return esmNOTIMPLEMENTED;
  167. #endif PROFIL
  168. }
  169.  
  170.  
  171.  void
  172. DumpCore ()
  173. {
  174.     fprintf(stderr, "SERVER %d aborting; creating core file...\n", getpid());
  175.     abort();
  176. }
  177.  
  178.  
  179. #ifdef DEBUG
  180. #include "distr.h"
  181. #include "distr_globals.h"
  182.  
  183. int
  184. DebugSetVar(int var, int value)
  185. {
  186.     switch(var) {
  187.     case 0:
  188.         break;
  189.     case 1:
  190.         DebugDistrVote = value;
  191.         break;
  192.     case 2:
  193.         DebugCrashLoc = value;
  194.         break;
  195.     default:
  196.         fprintf(sm_ErrorStream, "Unknown debug variable %d", var);
  197.         return esmFAILURE;
  198.     }
  199.     return esmNOERROR;
  200. }
  201. int
  202. DebugGetVar(int var, int *value)
  203. {
  204.     switch(var) {
  205.     case 0:
  206.         break;
  207.     case 1:
  208.         *value = DebugDistrVote;
  209.         break;
  210.     case 2:
  211.         *value = DebugCrashLoc;
  212.         break;
  213.     default:
  214.         return esmFAILURE;
  215.     }
  216.     return esmNOERROR;
  217. }
  218. #endif DEBUG
  219.